package com.chengv.redismq.annotation;

import java.lang.annotation.*;

/**
 * 消息监听注解
 *
 * @author chengv
 */
@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RedisMQMessageListener {

    /**
     * 消息主题
     */
    String topic();

    /**
     * 消费者组
     */
    String consumerGroup() default "default_consumer_group";
}
